package net.unix8.process;

import java.util.concurrent.ArrayBlockingQueue;

import net.unix8.bean.DAData;


public class ProducerDA {
	private final ArrayBlockingQueue<DAData> daQueue;  
	private final ArrayBlockingQueue<DAData> getDataQueue;  

	public ProducerDA(ArrayBlockingQueue<DAData> queue,ArrayBlockingQueue<DAData> getDataQueue){  
		this.daQueue = queue;  
		this.getDataQueue = getDataQueue;
	}  

	public void clearDa(){
		daQueue.clear();
	}
	public void produceDa(DAData data){  
		daQueue.offer(data);  
	}

	public void clearGetData(){
		getDataQueue.clear();
	}
	public void produceGetDa(DAData data){  
		getDataQueue.offer(data);  
	}
}
